package com.pengheng.sink.common;

import com.pengheng.bean.WaterSensor;

import java.io.Serializable;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class WaterSensorSupplier implements JdbcSupplier<WaterSensor>, Serializable {
    @Override
    public void get(PreparedStatement preparedStatement, WaterSensor waterSensor) throws SQLException {
        preparedStatement.setString(1, waterSensor.getId());
        preparedStatement.setLong(2, waterSensor.getTs());
        preparedStatement.setInt(3, waterSensor.getVc());
    }
}
